package com.xdf.ecommerce.stream.customChannel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 自定义接受信道（输入信道），用于接受消息
 * @author chanchaw
 * @create 2025-11-06 15:54
 */
public interface MySink {
    String INPUT = "ccInput";
    /* 输入信道的名称是 ccInput，需要使用 Stream 绑定器在 yml 文件中配置 */
    @Input(MySink.INPUT)
    SubscribableChannel ccInput();
}
